package com.kenliang.kafka;

import  org.apache.kafka.common.serialization.Serializer;

import java.util.Map;

/**
 * @Author:LiangTao
 * @Description:
 * @Date: Created in 17:07 2018/12/2.
 */
public class TestSerializer implements Serializer<Object> {
    @Override
    public void configure(Map<String, ?> configs, boolean isKey) {

    }

    @Override
    public byte[] serialize(String topic, Object data) {
        return new byte[0];
    }

    @Override
    public void close() {

    }
}
